package com.happy.xiao.common.rabbitmq.db.service;

import com.happy.xiao.common.rabbitmq.db.entity.MessageFailLog;

public interface IMessageFailLogService {


    void add(MessageFailLog obj);

    /**
     * 失败消息入库
     *
     * @param messageId
     * @param exchange
     * @param routingKey
     * @param message
     * @param expiration
     * @param failType   0 发送失败  1 消费失败
     */
    void createFailMessageInDB(String messageId,
                               String exchange,
                               String routingKey,
                               String message,
                               String expiration,
                               int failType);

}
